2de6bba345b895b68dfe4c27fd1fa98d137223e7,modules/hadoop/src/main/java/org/gridgain/grid/kernal/processors/hadoop/v1/GridHadoopV1CombineTask.java,GridHadoopV1CombineTask,run,#GridHadoopTaskContext#,32

Before Change


    @Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
        GridHadoopV2Job jobImpl = (GridHadoopV2Job) taskCtx.job();

        JobConf jobConf = jobImpl.hadoopJobContext().getJobConf();

        Reducer combiner = U.newInstance(jobConf.getCombinerClass());

After Change


    @Override public void run(final GridHadoopTaskContext taskCtx) throws GridInterruptedException, GridException {
        GridHadoopV2Job jobImpl = (GridHadoopV2Job) taskCtx.job();

        JobConf jobConf = new JobConf(jobImpl.hadoopJobContext().getJobConf());

        Reducer combiner = U.newInstance(jobConf.getCombinerClass());